//   Copyright 2012,2013 Vaughn Vernon
//
//   Licensed under the Apache License, Version 2.0 (the "License");
//   you may not use this file except in compliance with the License.
//   You may obtain a copy of the License at
//
//       http://www.apache.org/licenses/LICENSE-2.0
//
//   Unless required by applicable law or agreed to in writing, software
//   distributed under the License is distributed on an "AS IS" BASIS,
//   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//   See the License for the specific language governing permissions and
//   limitations under the License.

package com.saasovation.agilepm.port.adapter.messaging.rabbitmq;

import java.util.Date;

import com.saasovation.agilepm.application.team.DisableProductOwnerCommand;
import com.saasovation.agilepm.application.team.DisableTeamMemberCommand;
import com.saasovation.agilepm.application.team.TeamApplicationService;
import com.saasovation.common.notification.NotificationReader;
import com.saasovation.common.port.adapter.messaging.Exchanges;
import com.saasovation.common.port.adapter.messaging.rabbitmq.ExchangeListener;

/**
 * RabbitMQ团队成员禁用器监听器
 * @author learn
 */
public class RabbitMQTeamMemberDisablerListener extends ExchangeListener {
    /**
     * 团队应用服务
     */
    private TeamApplicationService teamApplicationService;

    /**
     * 由团队应用服务构造：RabbitMQ团队成员禁用器监听器
     * @param aTeamApplicationService          团队应用服务
     */
    public RabbitMQTeamMemberDisablerListener(
            TeamApplicationService aTeamApplicationService) {

        super();

        this.teamApplicationService = aTeamApplicationService;
    }
    /**
     * 获取回答监听到的交换名
     * @return      返回字符串
     */
    @Override
    protected String exchangeName() {
        return Exchanges.IDENTITY_ACCESS_EXCHANGE_NAME;
    }
    /**
     * 已删选的分配
     * @param aType the String message type
     * @param aTextMessage the String raw text message being handled
     */
    @Override
    protected void filteredDispatch(String aType, String aTextMessage) {
        // 通知阅读器
        NotificationReader reader = new NotificationReader(aTextMessage);
        // 使用此阅读器读取权限名
        String roleName = reader.eventStringValue("roleName");
        // 如果权限名不是敏捷产品经理 且 不是敏捷团队成员；则返回
        if (!roleName.equals("ScrumProductOwner") &&
            !roleName.equals("ScrumTeamMember")) {
            return;
        }
        // 使用此阅读器读取对应的值
        String tenantId = reader.eventStringValue("tenantId.id");
        String username = reader.eventStringValue("username");
        Date occurredOn = reader.occurredOn();
        // 如果权限名是敏捷产品经理
        if (roleName.equals("ScrumProductOwner")) {
            // 团队应用服务启用产品经理
            this.teamApplicationService().disableProductOwner(
                    new DisableProductOwnerCommand(
                        tenantId,
                        username,
                        occurredOn));
        } else {
            // 不是敏捷产品经理的话，团队应用服务启用团队成员
            this.teamApplicationService().disableTeamMember(
                    new DisableTeamMemberCommand(
                        tenantId,
                        username,
                        occurredOn));
        }
    }
    /**
     * 监听...
     * @return      返回字符串数组
     */
    @Override
    protected String[] listensTo() {
        return new String[] {
                "com.saasovation.identityaccess.domain.model.access.UserUnassignedFromRole"
                };
    }
    /**
     * 获取团队应用服务
     * @return      返回团队应用服务
     */
    private TeamApplicationService teamApplicationService() {
        return this.teamApplicationService;
    }
}
